New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Fixed wakeup bug in NioOutboundPipeline #14831
Fixed wakeup bug in NioOutboundPipeline #14831
Conversation
587c1d9
to
f3acbac
Compare
hazelcast/src/main/java/com/hazelcast/internal/networking/nio/NioOutboundPipeline.java
Show resolved
Hide resolved
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Just a minor comment WRT backward compatible probe values. Otherwise LGTM.
f3acbac
to
4d8d274
Compare
I have addressed your comment @kwart . Can you have another look? |
private long isScheduled() { | ||
return scheduled.get() ? 1 : 0; | ||
private long scheduled() { | ||
return scheduled.get().ordinal(); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
This is rather unconventional. Any reason we can't use something like return scheduled.get() == State.SCHEDULED ? 1 : 0
?
I'm thinking if someone changes the order. The value of this method returns as well.
Fixes #14830.